package com.lintf.distributed.transaction.order.service;

import com.baomidou.mybatisplus.extension.service.IService;
import com.lintf.distributed.transaction.order.entity.Message;

import java.util.List;

/**
 * @author lin tingfeng
 * @ system Mac
 * @ data 2025/6/12 17:35
 * @ package_name com.lintf.distributed.transaction.order.service
 * @ project_name distributed-transaction-demo
 * @ desc
 */
public interface MessageService extends IService<Message> {

    List<Message> findMessagesByStatus(Integer status);

    List<Message> findMessageByTimeout(Integer status, Long timeout);

    int incrementRetryCount(Message message);

}
